import org.apache.log4j.{Level, Logger}
import org.apache.spark.sql.{DataFrame, Dataset, SparkSession}

object ReadParquet {
  def main(args: Array[String]): Unit = {
    val session: SparkSession = SparkSession.builder().appName("GeoHashDict").master("local[4]").getOrCreate()
    import session.implicits._
    Logger.getLogger("org").setLevel(Level.INFO)

    val frame: DataFrame = session.read.parquet("data/dict/geo_dict/output")
    frame.show(50)

    session.close()
  }
}
